from spider.util import MysqlClient

TBL_NAME = 'brand_diagnosis_myuser'   # 根据自己的情况，修改表名称

class SpiderPipeline:
    client = None

    def open_spider(self, spider):
        self.client = MysqlClient()

    def process_item(self, item, spider):
        if spider.name == 'brand_diagnosis':    # 这里一定要判断类型，只有属于自己的Item才能使用
            sql = 'INSERT INTO '+TBL_NAME+'(name, age) VALUES (%s, %s)'
            self.client.execute(sql, (item['name'], item['age']))
            pass    # 上面两行是示例代码
        return item # 最后一定要返回item